package com.liuguang.rabbitmq.pojo;

import com.liuguang.common.pojo.MqData;
import lombok.Data;
import lombok.ToString;
import org.springframework.amqp.rabbit.connection.CorrelationData;

/**
 * @ClassName: MyCorrelationData
 * @Description： 自定义的关联数据，用来处理 confrimCallback 后，消息重发的
 * @Author: wanghr
 * Date: 2:14 PM 2020/11/6
 * Version: 1.0
 */
@Data
@ToString
public class MyCorrelationData extends CorrelationData {
    private String id;
    private String exchangeName;
    private String routingKey;
    private MqData mqData;

    public MyCorrelationData() {
    }

    public MyCorrelationData(String id) {
        super(id);
    }

    public MyCorrelationData(String id, String exchangeName, String routingKey, MqData mqData) {
        super(id);
        this.id = id;
        this.exchangeName = exchangeName;
        this.routingKey = routingKey;
        this.mqData = mqData;
    }
}
